package observable.emitter

/**
 * 替换直接创建被观察者
 */
interface ObservableOnSubscribe<T> {
    fun subscribe(emitter: Emitter<T>)
}